package cn.me.alphamq.common.entity.req;

import cn.me.alphamq.common.entity.BaseMsg;

/**
 * 创建 topic 的请求对象
 *
 * @author f
 */
public class CreateTopicReq extends BaseMsg {

    /**
     * topic 的名称
     */
    private String topicName;

    /**
     * topic 的队列数
     */
    private Integer queueSize;

    public CreateTopicReq() {
    }

    public CreateTopicReq(String topicName, Integer queueSize) {
        this.topicName = topicName;
        this.queueSize = queueSize;
    }

    public String getTopicName() {
        return topicName;
    }

    public void setTopicName(String topicName) {
        this.topicName = topicName;
    }

    public Integer getQueueSize() {
        return queueSize;
    }

    public void setQueueSize(Integer queueSize) {
        this.queueSize = queueSize;
    }
}
